package operator.function.do_;

import io.reactivex.Observable;
import io.reactivex.functions.Action;
import util.Printer;
import util.RxJavaHelper;

class DoOnCompleteOperator {

    public static void main(String[] args) {
        doOnComplete();
    }

    static void doOnComplete(){
        Observable.just(1)
                .doOnComplete(new Action() {
                    @Override
                    public void run() throws Exception {
                        Printer.print("doOnComplete");
                    }
                })
                .subscribe(RxJavaHelper.getConsumer());
    }


}
